package com.baofu.paycore.biz.notice;

import com.system.kafka.clients.ConsumerService;
import com.system.kafka.clients.handle.BizHandleInterface;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j;

/**
 * kafka消费者
 *
 * User: xin deng  Date: 16/5/18 ProjectName: paycore Version: 1.0
 */
@Slf4j
@Setter
public class CustomerHandler {

    /**
     * 消费者服务类
     */
    private ConsumerService consumerService;

    /**
     * 主题
     */
    private String topicName;

    /**
     * 接收到消息后,发送给"谁"进行处理
     */
    private Class<BizHandleInterface> receiptObj;

    /**
     * 传输的对象
     */
    private Class transObj;

    /**
     * 消费者启动执行
     * 注意:不同的消费者只允许调用1次.
     */
    public void execute() {
        log.info("统一支付消费者启动,topic:[{}]", topicName);

        consumerService.consumerMessages(topicName, receiptObj, transObj);
    }
}
